var mongodb = require('./db');

function Comment(comment) {
    this.title = comment.title;
    this.content = comment.content;
};

module.exports = Comment;

//存储用户信息
Comment.prototype.save = function(callback) {
    //要存入数据库的用户文档
    var comment = {
        title: this.title,
        content: this.content
    };
    //打开数据库
    mongodb.open(function (err, db) {
        if (err) {
            return callback(err);//错误，返回 err 信息
        }
        //读取 users 集合
        db.collection('comments', function (err, collection) {
            if (err) {
                mongodb.close();
                return callback(err);//错误，返回 err 信息
            }
            //将用户数据插入 users 集合
            collection.insert(comment, {
                safe: true
            }, function (err, comment) {
                mongodb.close();
                if (err) {
                    return callback(err);//错误，返回 err 信息
                }
                callback(null, comment[0]);//成功！err 为 null，并返回存储后的用户文档
            });
        });
    });
};

Comment.get = function(title, callback) {
    //打开数据库
    mongodb.open(function (err, db) {
        if (err) {
            return callback(err);//错误，返回 err 信息
        }
        //读取 users 集合
        db.collection('comments', function (err, collection) {
            if (err) {
                mongodb.close();
                return callback(err);//错误，返回 err 信息
            }
            //查找用户名（name键）值为 name 一个文档
            collection.findOne({
                title: title
            }, function (err,title) {
                mongodb.close();
                if (err) {
                    return callback(err);//失败！返回 err 信息
                }
                callback(null,title);//成功！返回查询的用户信息
            });
        });
    });
};